package com.xuxu.util;

import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;



/**
 * 这是一个RabbitMQ的工具类，抽取了公共的方法，用来获取连接对象 connection
 * 操作步骤：
 *  1.创建ConnectionFactory工厂对象
 *   1.2.设置主机地址
 *   1.3.设置端口号
 *   1.4.设置虚拟主机地址
 *   1.5.设置用户名
 *   1.6.设置密码
 *  2.最后返回连接对象
 */
public class RabbitConnectionUtil {

    /**
     * 这是一个获取连接对象的静态方法，用来获取一个连接对象
     * @return RabbitMQ连接对象 connection
     * @throws Exception
     */
    public static Connection getConnection() throws Exception {
        //创建工厂对象
        ConnectionFactory connectionFactory = new ConnectionFactory();
        //设置主机地址
        connectionFactory.setHost("localhost");
        //设置端口号
        connectionFactory.setPort(5672);
        //设置虚拟主机地址,就相当于mysql下面的 数据库的名称
        connectionFactory.setVirtualHost("/xuxu");
        //设置用户名
        connectionFactory.setUsername("xuxu");
        //设置密码
        connectionFactory.setPassword("123");
        //获取连接对象
        Connection connection = connectionFactory.newConnection();
        //返回连接对象
        return connection;
    }
}
